package com.jzl.canal_consumer.etl.et.rocketmq.consumer;

/**
 * @author ZhenWuWang
 */
public interface CanalRocketMqConsumer
{
    void start();

    void stop();
}
